package com.youku.collector;

import java.util.concurrent.BlockingQueue;

public interface Task<E> extends Runnable {

	public BlockingQueue<E> getQueue();

	public void put(E element) throws InterruptedException;

	public E take() throws InterruptedException;
}
